package cn.me.alphamq.broker.event.model.broker;

import cn.me.alphamq.common.entity.req.RetryConsumeMsgReq;
import cn.me.alphamq.common.event.model.Event;

/**
 * 重试消费消息的事件
 *
 * @author f
 */
public class RetryConsumeMsgEvent extends Event {

    private final RetryConsumeMsgReq retryConsumeMsgReq;

    public RetryConsumeMsgEvent(RetryConsumeMsgReq retryConsumeMsgReq) {
        this.retryConsumeMsgReq = retryConsumeMsgReq;
    }

    public RetryConsumeMsgReq getRetryConsumeMsgReq() {
        return retryConsumeMsgReq;
    }
}
